package mqs

import (
	"context"
	"go-weixin/app/mqueue/tasks/internal/svc"

	"github.com/zeromicro/go-zero/core/logx"
)

type MyDqTask struct {
	ctx    context.Context
	svcCtx *svc.ServiceContext
}

func NewDqConsumer(ctx context.Context, svcCtx *svc.ServiceContext) *MyDqTask {
	return &MyDqTask{
		ctx:    ctx,
		svcCtx: svcCtx,
	}
}

func (l *MyDqTask) Start() {
	logx.Info("延时队列启动")
	// 消费者
	l.svcCtx.DqConsumer.Consume(func(body []byte) {
		logx.Infof("执行延时任务: %s \n", string(body))
	})
}

func (l *MyDqTask) Stop() {
	logx.Error("消息队列停止, 假消息")
}
